// http.ts
import axios, {AxiosRequestConfig, AxiosResponse} from "axios"
import qs from "qs"
import store from "@/store"
import {getToken} from "@/utils/common";

const loadingBarHandler = (name: string) => {
    store.commit(name)
}


// 声明一个 Map 用于存储每个请求的标识 和 取消函数
const pending = new Map()
/**
 * 添加请求
 * @param {Object} config
 */
const addPending = (config: AxiosRequestConfig) => {
    const url = [
        config.method,
        config.url,
        qs.stringify(config.params),
        qs.stringify(config.data),
    ].join("&")
    config.cancelToken = config.cancelToken || new axios.CancelToken(cancel => {
        if (!pending.has(url)) { // 如果 pending 中不存在当前请求，则添加进去
            pending.set(url, cancel)
        }
    })
}
/**
 * 移除请求
 * @param {Object} config
 */
const removePending = (config: AxiosRequestConfig) => {
    const url = [
        config.method,
        config.url,
        qs.stringify(config.params),
        qs.stringify(config.data),
    ].join("&")
    if (pending.has(url)) { // 如果在 pending 中存在当前请求标识，需要取消当前请求，并且移除
        const cancel = pending.get(url)
        cancel(url)
        pending.delete(url)
    }
}

/**
 * 清空 pending 中的请求（在路由跳转时调用）
 */
export const clearPending = () => {
    for (const [url, cancel] of pending) {
        cancel(url)
    }
    pending.clear()
}

/**
 * 创建service
 */
const service = axios.create({
    baseURL: import.meta.env.VITE_BASE_URL,
    withCredentials: false, // send cookies when cross-domain requests
    timeout: 5000, // request timeout
})

// 请求拦截器
service.interceptors.request.use((config: AxiosRequestConfig) => {
    loadingBarHandler("loadingBarStart")

    removePending(config) // 在请求开始前，对之前的请求做检查取消操作
    addPending(config) // 将当前请求添加到 pending 中
    let token = getToken()
    if (token) {
        if (config?.headers) {
            config.headers.Authorization = `${token}`
        }
    }
    return config
}, (error: { data: { msg?: any } }) => {
    // 错误抛到业务代码
    error.data = {}
    error.data.msg = "服务器异常，请联系管理员！"
    loadingBarHandler("loadingBarError")
    window.$message?.error(error.data.msg)

    return Promise.resolve(error)
})

// 响应拦截器
service.interceptors.response.use((response: AxiosResponse) => {
    removePending(response) // 在请求结束后，移除本次请求
    const status = response.status
    let msg = ""
    if (status < 200 || status >= 300) {
        // 处理http错误，抛到业务代码
        msg = showStatus(status)
        if (typeof response.data === "string") {
            response.data = {msg}
        } else {
            response.data.msg = msg
        }
    }
    loadingBarHandler("loadingBarFinish")

    return response.data
// }, (error: { message: string; data: { msg?: any } }) => {
}, (error: any) => {
    loadingBarHandler("loadingBarError")
    if (axios.isCancel(error)) {
        console.log("repeated request: " + error.message)
    } else {
        // handle error code
        // 错误抛到业务代码
        error.data = {}
        if (error.response.status) {
            error.data.msg = "URL地址错误！"
        } else {
            error.data.msg = "请求超时或服务器异常，请检查网络或联系管理员！"
        }
        window.$message?.error(error.data.msg)
    }
    return Promise.reject(error)
})

function showStatus(status: number): string {
    throw new Error("Function not implemented.")
}

export default service



